package com.atguigu.tingshu.order.api;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.TimeUnit;

/**
 * @author atguigu-mqx
 * @ClassName Test
 * @description: TODO
 * @date 2024年06月21日
 * @version: 1.0
 */
public class Test {
    public static void main(String[] args) throws InterruptedException {
        //  当队列满的时候，再向队列中添加元素； 当队列为空的时候，从队列获取数据；
        ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
        //  阻塞功能！
        //        queue.put("a");
        //        queue.put("b");
        //        queue.put("c");
        //        System.out.println(queue.take());
        //        System.out.println("添加满了....");
        //        queue.put("d");
        //        System.out.println("over...");
        System.out.println(queue.offer("a",3, TimeUnit.SECONDS));
        System.out.println(queue.take());

//        System.out.println(queue.offer("b",3, TimeUnit.SECONDS));
//        System.out.println(queue.offer("c",3, TimeUnit.SECONDS));
        System.out.println(queue.offer("d",3, TimeUnit.SECONDS));
        System.out.println("over...");


    }
}
